# -*- coding: utf-8 -*-
# @Author: Tim Liu
# @Date: 2025-01-08
# @Last Modified by: Cursor
# @Last Modified time: 2025-01-08

# @Description: OSchema DAL for RAG

from sqlalchemy.ext.asyncio import AsyncSession
from core.crud import DalBase
from crewplus.apps.rag import models, schemas

class OSchemaDal(DalBase):

    def __init__(self, db: AsyncSession):
        super(OSchemaDal, self).__init__()
        self.db = db
        self.model = models.OSchemaDB
        self.schema = schemas.OSchemaSimpleOut
    